package cn.stronglink.asset.module.dam.utils.dataJsonUtils.realtime.send;

import cn.stronglink.asset.message.mq.dam.MsgSender;
import cn.stronglink.suite.core.util.ContextUtils;

public class MsgSendUtil {
	
	/** 持有发射器：topicSender.send("主题名", 数据);*/
	private static MsgSender topicSender= (MsgSender) ContextUtils.getBean("webToDamMessageSender");
	 	
	/** 发送消息： 发射器的topicSender.send("主题名", 数据); */
	 public static void sendMsg(String topicName,String finalCommand) {
	 		System.out.println("最终发送的指令：===" + finalCommand);
	 		topicSender.send(topicName, finalCommand);
	 		
	 }
}
